package com.banyou.banyou.login.regist;

import android.content.Context;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.banyou.banyou.bean.CodeBean;
import com.banyou.banyou.bean.login.regist.RegistBean;
import com.banyou.banyou.webutils.ProgressSubscriber;
import com.banyou.banyou.webutils.ResponseCallBack;
import com.banyou.banyou.webutils.RetrofitHelp;
import com.banyou.banyou.webutils.SubscriberOnErrorListener;
import com.banyou.banyou.webutils.SubscriberOnNextListener;
import com.socks.library.KLog;

import java.util.Map;

import okhttp3.MediaType;
import okhttp3.RequestBody;
import rx.Observable;

/**
 * ----------Dragon be here!----------/
 * 　　　┏┓　　　┏┓
 * 　　┏┛┻━━━┛┻┓
 * 　　┃　　　　　　　┃
 * 　　┃　　　━　　　┃
 * 　　┃　┳┛　┗┳　┃
 * 　　┃　　　　　　　┃
 * 　　┃　　　┻　　　┃
 * 　　┃　　　　　　　┃
 * 　　┗━┓　　　┏━┛
 * 　　　　┃　　　┃神兽保佑
 * 　　　　┃　　　┃代码无BUG！
 * 　　　　┃　　　┗━━━┓
 * 　　　　┃　　　　　　　┣┓
 * 　　　　┃　　　　　　　┏┛
 * 　　　　┗┓┓┏━┳┓┏┛
 * 　　　　　┃┫┫　┃┫┫
 * 　　　　　┗┻┛　┗┻┛
 * ━━━━━━神兽出没━━━━━━
 * 类描述：
 * 创建人：Random
 * 修改时间：
 * 修改备注：
 */

public class RegistModel implements RegistContract.Model {
    private SubscriberOnNextListener<CodeBean> mListener;
    private SubscriberOnErrorListener mErrorListener;
    private Context mContext;

    /**
     * 获取验证码
     *
     * @param phoneNum
     */
    @Override
    public void getCode(String phoneNum) {
        ResponseCallBack callBack = RetrofitHelp.getResponseCallBack();
        RetrofitHelp help = RetrofitHelp.getInstance();
        Observable observable = callBack.getCode(phoneNum).map(help.new HttpResultFunc());
        RetrofitHelp.toSubscribe(observable, new ProgressSubscriber(mListener, mContext, true, mErrorListener));
    }


    public void setListener(SubscriberOnNextListener onNext, SubscriberOnErrorListener onError, Context context) {
        mListener = onNext;
        mErrorListener = onError;
        mContext = context;
    }

    private SubscriberOnNextListener<CodeBean> mRegistOnNext;
    private SubscriberOnErrorListener mRegistOnError;

    @Override
    public void regist(Map<String,String> json) {
        ResponseCallBack callBack = RetrofitHelp.getResponseCallBack();
        RetrofitHelp help = RetrofitHelp.getInstance();
        KLog.i("json="+json);
        Observable observable = callBack.regist(json).map(help.new HttpResultFunc<CodeBean>());
        RetrofitHelp.toSubscribe(observable, new ProgressSubscriber(mRegistOnNext, mContext, true, mRegistOnError));
    }

    public void setRegistListener(SubscriberOnNextListener onNext, SubscriberOnErrorListener onError, Context context) {
        mRegistOnNext = onNext;
        mRegistOnError = onError;
        mContext = context;
    }
}
